|
|
@@ -3,10 +3,10 @@ require 'mqtt'
|
3
|
3
|
require './spec/support/fake_mqtt_server'
|
4
|
4
|
|
5
|
5
|
describe Agents::MqttAgent do
|
|
6
|
+
|
6
|
7
|
before :each do
|
7
|
|
- # stub_request(:get, /parse/).to_return(:body => File.read(Rails.root.join("spec/data_fixtures/adioso_parse.json")), :status => 200, :headers => {"Content-Type" => "text/json"})
|
8
|
|
- # stub_request(:get, /fares/).to_return(:body => File.read(Rails.root.join("spec/data_fixtures/adioso_fare.json")), :status => 200, :headers => {"Content-Type" => "text/json"})
|
9
|
8
|
@error_log = StringIO.new
|
|
9
|
+
|
10
|
10
|
@server = MQTT::FakeServer.new(1234, '127.0.0.1')
|
11
|
11
|
@server.just_one = true
|
12
|
12
|
@server.logger = Logger.new(@error_log)
|